package com.jzl.canal_consumer.etl.et.rocketmq.connector;

import com.alibaba.otter.canal.client.CanalConnector;
import com.alibaba.otter.canal.protocol.exception.CanalClientException;

import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 * @author ZhenWuWang
 */
public interface CanalRocketMqConnector<T> extends CanalConnector
{
    List<T> getList(Long timeout, TimeUnit timeUnit) throws CanalClientException;

    List<T> getListWithoutAck(Long timeout, TimeUnit timeUnit) throws CanalClientException;

    void ack() throws CanalClientException;

    String getGroupName();

    String[] getTopic();

    String getNameServer();
}
